package Flink.function;

import Flink.bean.WaterSensor;
import org.apache.flink.api.common.functions.MapFunction;

public class UserMap implements MapFunction<WaterSensor, String> {

    @Override
    public String map(WaterSensor value) throws Exception {
        return value.getId();
    }
}
